package com.shiguiwu.springboot3.redis.mq;


import cn.hutool.json.JSONUtil;
import com.shiguiwu.springboot3.dto.UserDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class ConsumeService {

    public void processMessage(String channel,String message) {
        // 可以根据channel再继续映射到不同的实现
        UserDTO userDto = JSONUtil.toBean(message, UserDTO.class);
        log.info("接收的结果：{}", userDto);
        // 做业务...
        // 还可以分布式锁幂等处理
    }
}
